package com.udf.flink.udsf;

import org.apache.flink.table.functions.ScalarFunction;

import java.sql.Timestamp;

public class TsToLong extends ScalarFunction {
    public Long eval(Timestamp s) {
        return s.getTime();
    }
}
